<?php

namespace app\store\model;

use app\common\model\User as UserModel;

use app\store\model\dealer\User as DealerUserModel;
use app\store\model\user\GradeLog as GradeLogModel;
use app\store\model\user\PointsLog as PointsLogModel;
use app\store\model\user\BalanceLog as BalanceLogModel;
use app\common\enum\user\balanceLog\Scene as SceneEnum;
use app\common\enum\user\grade\log\ChangeType as ChangeTypeEnum;
use app\common\library\helper;

/**
 * 用户模型
 * Class User
 * @package app\store\model
 */
class User extends UserModel
{
    /**
     * 获取当前用户总数
     * @param null $day
     * @return int|string
     * @throws \think\Exception
     */
    public function getUserTotal($day = null)
    {
        if (!is_null($day)) {
            $startTime = strtotime($day);
            $this->where('create_time', '>=', $startTime)
                ->where('create_time', '<', $startTime + 86400);
        }
        return $this->where('is_delete', '=', '0')->count();
    }

    /**
     * 获取用户列表
     * @param string $key 
     * @param int $start_time 
     * @param int $end_time 
     * @return \think\Paginator
     * @throws \think\exception\DbException
     */
    // public function getList($key = '', $start_time = null, $end_time = null)
    // {
    //     $start_time = !empty($start_time) && is_string($start_time) ? strtotime($start_time) : $start_time;
    //     $end_time = !empty($end_time) && is_string($end_time) ? strtotime($end_time) : $end_time;

    //     // 如果只有开始时间或结束时间，默认设置为当天范围
    //     if (!empty($start_time) && empty($end_time)) {
    //         $end_time = strtotime(date('Y-m-d 23:59:59', $start_time)); // 设置结束时间为当天23:59:59
    //     }
    //     if (!empty($end_time) && empty($start_time)) {
    //         $start_time = strtotime(date('Y-m-d 00:00:00', $end_time)); // 设置开始时间为当天00:00:00
    //     }

    //     // 如果开始时间和结束时间相同，调整结束时间为当天23:59:59
    //     if (!empty($start_time) && $start_time === $end_time) {
    //         $end_time = strtotime(date('Y-m-d 23:59:59', $start_time));
    //     }


        
    //     // 添加搜索关键字
    //     if (!empty($key)) {
    //         $this->where(function ($query) use ($key) {
    //             $query->whereOr('u.nickName', 'like', "%$key%")
    //                 ->whereOr('uj.name', 'like', "%$key%")
    //                 ->whereOr('uj.phone', 'like', "%$key%");
    //         });
    //     }

    //     // 添加时间过滤条件
    //     if (!empty($start_time)) {
    //         $this->where('u.create_time', '>=', $start_time);
    //     }
    //     if (!empty($end_time)) {
    //         $this->where('u.create_time', '<=', $end_time);
    //     }

    //     // 查询用户列表，使用 LEFT JOIN
    //     return $this->alias('u')
    //         ->join('user_jiuzhen uj', 'u.user_id = uj.user_id', 'LEFT')  // 使用 'LEFT' 参数实现左连接
    //         ->where('u.is_delete', '=', '0')
    //         ->group('u.user_id')  // 按主表的 user_id 分组
    //         ->field([
    //             'u.*',
    //             'GROUP_CONCAT(uj.name SEPARATOR ",") as jiuzhen_names',  // 聚合字段
    //             'GROUP_CONCAT(uj.phone SEPARATOR ",") as jiuzhen_phones'
    //         ])
    //         ->order(['u.create_time' => 'desc'])
    //         ->paginate(15, false, [
    //             'query' => request()->request()
    //         ]);
    // }
public function getList($key = '', $start_time = null, $end_time = null)
{
    // 规范化时间入参：字符串转时间戳
    $start_time = !empty($start_time) && is_string($start_time) ? strtotime($start_time) : $start_time;
    $end_time   = !empty($end_time)   && is_string($end_time)   ? strtotime($end_time)   : $end_time;

    // 只有开始时间：补到当天 23:59:59
    if (!empty($start_time) && empty($end_time)) {
        $end_time = strtotime(date('Y-m-d 23:59:59', $start_time));
    }
    // 只有结束时间：补到当天 00:00:00
    if (!empty($end_time) && empty($start_time)) {
        $start_time = strtotime(date('Y-m-d 00:00:00', $end_time));
    }
    // 相同日期：把结束时间拉到当天 23:59:59
    if (!empty($start_time) && $start_time === $end_time) {
        $end_time = strtotime(date('Y-m-d 23:59:59', $start_time));
    }

    // 先搭好查询骨架（先 alias / join，再加筛选）
    $qb = $this->alias('u')
        ->join('user_jiuzhen uj', 'u.user_id = uj.user_id', 'LEFT')
        ->where('u.is_delete', 0);

    // 关键字搜索（昵称/就诊人姓名/就诊人手机号）
    // 你表里微信昵称字段如果是 nickname（不是 nickName），自己改一下
    $key = trim((string)$key);
    if ($key !== '') {
        $digits = preg_replace('/\D+/', '', $key); // 只取数字给手机号模糊
        $qb->where(function($w) use ($key, $digits) {
            $like = '%' . $key . '%';
            $w->where('u.nickname', 'like', $like)   // 如果字段叫 nickName 改回 nickName
              ->whereOr('uj.name', 'like', $like);

            if ($digits !== '') {
                $w->whereOr('uj.phone', 'like', '%' . $digits . '%');
            }
        });
    }

    // 时间过滤（按用户创建时间）
    if (!empty($start_time)) {
        $qb->where('u.create_time', '>=', $start_time);
    }
    if (!empty($end_time)) {
        $qb->where('u.create_time', '<=', $end_time);
    }

    // 查询与聚合
    return $qb->group('u.user_id')
        ->field([
            'u.*',
            // DISTINCT 防止一个人多条就诊记录造成重复
            'GROUP_CONCAT(DISTINCT uj.name  SEPARATOR ",")  AS jiuzhen_names',
            'GROUP_CONCAT(DISTINCT uj.phone SEPARATOR ",")  AS jiuzhen_phones',
        ])
        ->order(['u.create_time' => 'desc'])
        ->paginate(15, false, [
            'query' => request()->request()
        ]);
}
    /**
     * 删除用户
     * @return bool|mixed
     */
    public function setDelete()
    {
        // 判断是否为分销商
        if (DealerUserModel::isDealerUser($this['user_id'])) {
            $this->error = '当前用户为分销商，不可删除';
            return false;
        }
        return $this->transaction(function () {
            // 删除用户推荐关系
            (new DealerUserModel)->onDeleteReferee($this['user_id']);
            // 标记为已删除
            return $this->save(['is_delete' => 1]);
        });
    }

    /**
     * 用户充值
     * @param string $storeUserName 当前操作人用户名
     * @param int $source 充值类型
     * @param array $data post数据
     * @return bool
     */
    public function recharge($storeUserName, $source, $data)
    {
        if ($source == 0) {
            return $this->rechargeToBalance($storeUserName, $data['balance']);
        } elseif ($source == 1) {
            return $this->rechargeToPoints($storeUserName, $data['points']);
        }
        return false;
    }

    /**
     * 用户充值：余额
     * @param $storeUserName
     * @param $data
     * @return bool
     */
    private function rechargeToBalance($storeUserName, $data)
    {
        if (!isset($data['money']) || $data['money'] === '' || $data['money'] < 0) {
            $this->error = '请输入正确的金额';
            return false;
        }
        // 判断充值方式，计算最终金额
        if ($data['mode'] === 'inc') {
            $diffMoney = $data['money'];
        } elseif ($data['mode'] === 'dec') {
            $diffMoney = -$data['money'];
        } else {
            $diffMoney = helper::bcsub($data['money'], $this['balance']);
        }
        // 更新记录
        $this->transaction(function () use ($storeUserName, $data, $diffMoney) {
            // 更新账户余额
            $this->setInc('balance', $diffMoney);
            // 新增余额变动记录
            BalanceLogModel::add(SceneEnum::ADMIN, [
                'user_id' => $this['user_id'],
                'money' => $diffMoney,
                'remark' => $data['remark'],
            ], [$storeUserName]);
        });
        return true;
    }

    /**
     * 用户充值：积分
     * @param $storeUserName
     * @param $data
     * @return bool
     */
    private function rechargeToPoints($storeUserName, $data)
    {
        if (!isset($data['value']) || $data['value'] === '' || $data['value'] < 0) {
            $this->error = '请输入正确的积分数量';
            return false;
        }
        // 判断充值方式，计算最终积分
        if ($data['mode'] === 'inc') {
            $diffMoney = $data['value'];
        } elseif ($data['mode'] === 'dec') {
            $diffMoney = -$data['value'];
        } else {
            $diffMoney = $data['value'] - $this['points'];
        }
        // 更新记录
        $this->transaction(function () use ($storeUserName, $data, $diffMoney) {
            // 更新账户积分
            $this->setInc('points', $diffMoney);
            // 新增积分变动记录
            PointsLogModel::add([
                'user_id' => $this['user_id'],
                'value' => $diffMoney,
                'describe' => "后台管理员 [{$storeUserName}] 操作",
                'remark' => $data['remark'],
            ]);
        });
        return true;
    }

    /**
     * 修改用户等级
     * @param $data
     * @return mixed
     */
    public function updateGrade($data)
    {
        // 变更前的等级id
        $oldGradeId = $this['grade_id'];
        return $this->transaction(function () use ($oldGradeId, $data) {
            // 更新用户的等级
            $status = $this->save(['grade_id' => $data['grade_id']]);
            // 新增用户等级修改记录
            if ($status) {
                (new GradeLogModel)->record([
                    'user_id' => $this['user_id'],
                    'old_grade_id' => $oldGradeId,
                    'new_grade_id' => $data['grade_id'],
                    'change_type' => ChangeTypeEnum::ADMIN_USER,
                    'remark' => $data['remark']
                ]);
            }
            return $status !== false;
        });
    }

    /**
     * 消减用户的实际消费金额
     * @param $userId
     * @param $expendMoney
     * @return int|true
     * @throws \think\Exception
     */
    public function setDecUserExpend($userId, $expendMoney)
    {
        return $this->where(['user_id' => $userId])->setDec('expend_money', $expendMoney);
    }

}
